package spring.cloud.tasks.executor.service;

import spring.cloud.tasks.metadata.api.task.entity.TaskRuntimeEntity;


public interface TaskHeartBeatQueueService {

    void add(Integer heartBeatRate, TaskRuntimeEntity taskRuntimeEntity);

    /**
     * 从队列移除掉这个任务
     * 正常停止的任务 可以清理掉运行信息 异常停止的任务 不清理运行信息
     */
    void remove(Integer heartBeatRate, TaskRuntimeEntity taskRuntimeEntity, boolean needClearRuntimeInfo);
}
